package com.hjh.netty.elect.demo1.controller;

import cn.hutool.core.util.StrUtil;
import com.hjh.netty.elect.demo1.common.ServerHandler;
import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/equipmentControl")
public class EquipmentController {


    @RequestMapping(value = "/equipment")
    public String equipment(@RequestParam("url") String url) {
        //入参 设备id   根据设备id  查询设备最后一次录入数据时候的 ip（url）地址  实现下发
        //需要给设备发送的 16进制数据
        String msg = " 16 27 88 90 12 45 31 15 41 ";
        //转码
        ByteBuf message = Unpooled.copiedBuffer(msg.getBytes());
        //执行设备控制    根据product.getUrl() 上个类写入map  的key  取到map中的 ChannelHandlerContext  执行writeAndFlush发送数据
        ServerHandler.map.get(StrUtil.trimToEmpty(url)).channel().writeAndFlush(message);
        return "success";
    }
}

